4cd382b04dfe3e0609172541cb5bfa15b2bcaa90,splice_machine/src/main/java/com/splicemachine/derby/stream/control/BadRecordsRecorder.java,BadRecordsRecorder,generateWritableFilePath,#String#String#String#,205
Before Change
private static Path generateWritableFilePath(String badDirectory,
String vtiFilePath,
String extension) throws StandardException {
DistributedFileSystem fileSystem = SIDriver.driver().fileSystem();
Path inputFilePath = fileSystem.getPath(vtiFilePath);
if (LOG.isTraceEnabled())
SpliceLogUtils.trace(LOG, "BadRecordsRecorder: badDirectory=%s, filePath=%s", badDirectory, inputFilePath);
After Change
String vtiFilePath,
String extension) throws StandardException {
try {
DistributedFileSystem fileSystem = SIDriver.driver().getSIEnvironment().fileSystem(vtiFilePath);
Path inputFilePath = fileSystem.getPath(vtiFilePath);
if (LOG.isTraceEnabled())
SpliceLogUtils.trace(LOG, "BadRecordsRecorder: badDirectory=%s, filePath=%s", badDirectory, inputFilePath);